package io.gitee.hechenl.datamultitrans.mqtt;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public interface MqttConsumer {

    String getTopic();

    void consumer(MqttMessage message);
}
